package pub.guoxin.oops.msg;

import org.apache.kafka.clients.consumer.ConsumerRecord;

public interface MessageDataListener {

    /**
     * 实现此方法需要在实现类的该方法上添加 @KafkaListener(topics = {YouTopicName})
     * <p>
     * 使用 consumerRecord.value() 方法来获得消息
     * <p>
     * eg:
     *  String data = consumerRecord.value();
     *
     * @param consumerRecord
     */
    void processMessage(ConsumerRecord<String, String> consumerRecord);

}
